package com.mxw.disruptor;

import com.lmax.disruptor.WorkHandler;
import lombok.Data;

@Data
public class MessageConsumer implements
        WorkHandler<TranslatorDataWapper> {

    protected String consumerId;

    public MessageConsumer(String consumerId) {
        this.consumerId = consumerId;
    }

    @Override
    public void onEvent(TranslatorDataWapper translatorDataWapper) throws Exception {

    }

}
